# -*- coding: utf-8 -*-
from airflow.operators.python import PythonOperator
from .cn_address_warehouse_day_rule_dt_parquet_sucess import main
from jms.dm.cn_address_warehouse_day_rule_dt_parquet import jms_dm__cn_address_warehouse_day_rule_dt_parquet


jms_dm__cn_address_warehouse_day_rule_dt_parquet_sucess = PythonOperator(
    task_id='jms_dm__cn_address_warehouse_day_rule_dt_parquet_sucess',
    email=['yushuo@jtexpress.com','yl_bigdata@yl-scm.com'],
    pool='unlimited_pool',
    python_callable=main,
    op_args=['{{ execution_date | cst_ds }}', '{{ var.json.mysq_sync_status2kafka }}'],
)

jms_dm__cn_address_warehouse_day_rule_dt_parquet_sucess << [jms_dm__cn_address_warehouse_day_rule_dt_parquet]